/*******************************************************************/
/* @ All Rights Reserved Copyright (C) 2014 broada,Co.,Ltd.        */
/*                                                                 */
/*  NAME      = amqp_content.h                                     */
/*  NOTE      =                                                    */
/*  DATE      = 2015/09/09 by geyh                                 */
/*******************************************************************/
#ifndef __AMQP_CONTENT_H_
#define __AMQP_CONTENT_H_

#include "amqp_basedata_type.h"

int amqp_skip_content(Frbyte_Packet *p_st_data, int *p_ui_skip_len);
int amqp_add_string(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, const char *p_field_name, int i_flag_need);
int amqp_get_string(Frbyte_Packet *p_st_data, char **pp_field_value, int *p_ui_skip_len);
int amqp_get_symbol(Frbyte_Packet *p_st_data, char **pp_field_value, int *p_ui_skip_len);
int amqp_add_uint(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, int *p_ui_skip_len, const char *p_field_name);
int amqp_add_arguments(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, st_amqp_private_data *p_st_private);
int amqp_add_mess_header(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, st_amqp_private_data *p_st_private);
int amqp_add_mess_properties(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, st_amqp_private_data *p_st_private);
int amqp_add_mess_content(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, st_amqp_private_data *p_st_private);
int amqp_add_disposition(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, st_amqp_private_data *p_st_private);
int amqp_get_username(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_amqp_private *p_st_session_private);
int amqp_get_responsecode(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, st_amqp_private_data *p_st_private, int *p_i_datatype);
int amqp_skip_long(Frbyte_Packet *p_st_data, int *p_i_skip_len);
int amqp_get_long(Frbyte_Packet *p_st_data, long long *p_ll_value);
int amqp_get_disposition_id(Frbyte_Packet *p_st_data, int *p_i_first_id, int *p_i_last_id);
int amqp_map_message_parse(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, int i_count, int i_use_request);
int amqp_get_content(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, const char *p_field_name , int i_use_request);

#endif
